| HBase Java API操作数据库 | 您所在的位置：网站首页 › 打开hbase shell › HBase Java API操作数据库 |
HBase Java API操作数据库
|
场景 在上面将开发环境搭建起来，要想操作操作数据库除了使用HBase Shell 还可以使用JAVA API对HBase进行操作。 注： 关注公众号 霸道的程序猿 获取编程相关电子书、教程推送与免费下载。 HBase Java API 与HBase数据模型的对应关系
1、首先在IDEA中新建Maven项目，pom文件中添加依赖 org.apache.hbase hbase-client 2.4.5 org.apache.hbase hbase-common 2.4.5 org.apache.hbase hbase-protocol 2.4.5 org.apache.hbase hbase-server 2.4.5 junit junit 4.122、然后新建包，包下新建类，首先新建建立连接和关闭连接的方法 public static Configuration cfg = HBaseConfiguration.create(); public static Connection conn; /** * 建立连接 * @throws IOException */ public static void getConn() throws IOException { cfg.set("hbase.zookeeper.quorum","192.168.148.128:2181,192.168.148.131:2181,192.168.148.132:2181"); //创建数据库连接 conn = ConnectionFactory.createConnection(cfg); } /** * 关闭连接 * @throws IOException */ public static void closeConn() throws IOException { conn.close(); }然后这里的zookeeper的配置参考上面配置HBase的hbase-site.xml中的配置。 这里配置的是master、slave1、slave2的ip,另外要在本地电脑hosts文件中加上集群节点的映射。
3、获取所有表，新建方法 /** * 列出所有的表 * @throws IOException */ public static void listAllTable() throws IOException { //Admin 用于管理HBase数据库的表信息 Admin admin = conn.getAdmin(); for(TableName name : admin.listTableNames()) { System.out.println(name); } }然后在main方法中调用 public static void main(String[] args) throws IOException { getConn(); listAllTable(); closeConn(); }
注意： org.apache.hadoop.hbase.client.Admin是为管理HBase而提供的接口，在Connection 实例调用getAdmin()和close()方法期间有效。使用Admin接口可以实现的主要 HBase Shell命令包括create, list, drop, enable, disable, alter，相应方法如下所示。
4、创建表方法 /* 创建表 */ public static void createTable(String tableName,String ...familyNames) throws IOException { //Admin 用于管理HBase数据库的表信息 Admin admin = conn.getAdmin(); //表名 TableName tn = TableName.valueOf(tableName); //如果表已经存在 if(admin.tableExists(tn)) { //先使表无效 admin.disableTable(tn); //删除表 admin.deleteTable(tn); } //HTableDescriptor 包含了表的名字及其对应的列族 HTableDescriptor hTableDescriptor = new HTableDescriptor(tn); for(String family:familyNames) { hTableDescriptor.addFamily(new HColumnDescriptor(family)); } admin.createTable(hTableDescriptor); admin.close(); }
5、查看表结构方法 /* 查看表结构 */ public static void describe(String tableName) throws IOException { Admin admin = conn.getAdmin(); TableName tn = TableName.valueOf(tableName); HTableDescriptor hTableDescriptor = admin.getTableDescriptor(tn); for(HColumnDescriptor hcd :hTableDescriptor.getColumnFamilies()) { System.out.println(hcd.getNameAsString()); } }
6、插入数据方法 /* 插入数据 */ public static void putdata() throws IOException { cfg.set("hbase.zookeeper.quorum","192.168.148.128:2181,192.168.148.131:2181,192.168.148.132:2181"); //创建数据库连接 conn = ConnectionFactory.createConnection(cfg); Table tb = conn.getTable(TableName.valueOf("scores")); Put p = new Put(Bytes.toBytes("zhangsan")); p.addColumn(Bytes.toBytes("grade"),Bytes.toBytes(""),Bytes.toBytes("3")); p.addColumn(Bytes.toBytes("grade"),Bytes.toBytes("math"),Bytes.toBytes("58")); p.addColumn(Bytes.toBytes("course"),Bytes.toBytes("art"),Bytes.toBytes("98")); tb.put(p); }
注意： Table接口用于和HBase中的表进行通信，代表了该表的实例，使用Connection的 getTable(TableName tableName)方法可以获取该接口的实例，用于获取、添加、删除、扫描HBase表中的数据。 Table接口包含的主要方法如下
7、获取数据方法 /* 获取数据 */ public static void getdata() throws IOException { cfg.set("hbase.zookeeper.quorum","192.168.148.128:2181,192.168.148.131:2181,192.168.148.132:2181"); //创建数据库连接 conn = ConnectionFactory.createConnection(cfg); Table tb = conn.getTable(TableName.valueOf("scores")); Get get = new Get(Bytes.toBytes("zhangsan")); //get.addFamily(Bytes.toBytes("grade")); //get.addColumn(Bytes.toBytes("grade"),Bytes.toBytes("math")); Result result = tb.get(get); System.out.println(String.format("resule.value=%s,resule.toString():%s",Bytes.toString(result.value()),result)); }注意： 按行键获取 Get get = new Get(Bytes.toBytes("zhangsan"));
按行键、列族获取 Get get = new Get(Bytes.toBytes("zhangsan")); get.addFamily(Bytes.toBytes("grade"));
按行键、列族、列修饰符获取 Get get = new Get(Bytes.toBytes("zhangsan")); get.addColumn(Bytes.toBytes("grade"),Bytes.toBytes("math"));
|
【本文地址】
公司简介
联系我们